package com.demo.order.restapi.mqchannel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface InputSource {
    String GOODSREPLYCHANNEL = "goodsreplychannel";
    String REPLYCHANNEL = "replychannel";

    @Output("goodsreplychannel")
    SubscribableChannel goodsReplyInput();

    @Input("replychannel")
    MessageChannel replyOutput();
}
